package cn.da.shuai.cool.mq.mqtt.service;

import cn.da.shuai.cool.mq.mqtt.constant.MqttConstant;
import org.springframework.integration.annotation.IntegrationComponentScan;
import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;

@IntegrationComponentScan
@MessagingGateway(defaultRequestChannel = MqttConstant.OUT_CHANNEL)
public interface ClientService {
    void send(@Header(MqttHeaders.TOPIC) String topic, String message);
}
